  let mysql = require("mysql");
  let {OPTIONS} = require("./config");

  // 1、创建一个连接对象
  let connection = mysql.createConnection(OPTIONS);
  // 2、尝试连接数据库
  connection.connect((err)=>{
    if(err){
      console.log("数据库连接失败");
      return;
    }
    console.log("数据库连接成功"+ connection.threadId );
  })

  // 3、 执行对数据库的CRUD
  function query(sql,arr){
    return new Promise((resolve,reject)=>{
      connection.query(sql,arr, (err,result)=>{
        if(!err){
          resolve(result);
        }else{
          reject(err);
        }
      })
    })
  }

  // 4、关闭连接数据库，释放资源
  function close(){
    connection.end();
  }

  module.exports = {
    query,
    close
  }